package cn.callmee.springboot.pulsar.starter.client.message;

import lombok.Getter;
import org.apache.pulsar.client.api.Consumer;
import org.apache.pulsar.client.api.Message;

public class FailedMessage {
    @Getter
    private final Exception exception;
    @Getter
    private final Consumer<?> consumer;
    @Getter
    private final Message<?> message;

    public FailedMessage(Exception exception, Consumer<?> consumer, Message<?> message) {
        this.exception = exception;
        this.consumer = consumer;
        this.message = message;
    }
}
